//package com.soxing.webrain.brush.service.webSocket;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.stereotype.Component;
//
//import javax.websocket.*;
//import javax.websocket.server.ServerEndpoint;
//import java.io.IOException;
//import java.util.concurrent.CopyOnWriteArraySet;
//
//@ServerEndpoint("/websocket/docker")  // ws://localhost:8080/websocket
//@Component
//public class DockerLogWebSocketServer {
//    private static final Logger logger = LoggerFactory.getLogger(DockerLogWebSocketServer.class);
//
//    private Session session;
//    private static CopyOnWriteArraySet<DockerLogWebSocketServer> webSocketSet = new CopyOnWriteArraySet<>();
//
//    @OnOpen
//    public void onOpen(Session session) {
//        logger.info("连接成功");
//        this.session = session;
//        webSocketSet.add(this);
//        // 可以在这里启动 Docker 日志监听
//    }
//
//    @OnClose
//    public void onClose() {
//        webSocketSet.remove(this);
//    }
//
//    @OnMessage
//    public void onMessage(String message, Session session) {
//        logger.info("接收到数据" + message);
//        // 可以处理前端发送的消息
//    }
//
//    @OnError
//    public void onError(Session session, Throwable error) {
//        error.printStackTrace();
//    }
//
//    // 用于将 Docker 日志发送到前端的方法
//    public static void sendMessage(String message) {
//        for (DockerLogWebSocketServer item : webSocketSet) {
//            try {
//                item.session.getBasicRemote().sendText(message);
//            } catch (IOException e) {
//                e.printStackTrace();
//            }
//        }
//    }
//}
